package com.yc.ycrpc.transport;

import com.yc.ycrpc.Peer;

import java.io.InputStream;

/**
 * 创建连接
 * 发送数据，并等待响应
 * 关闭连接
 * @author yc112
 */
public interface TransportClient {
    void connect(Peer peer);

    InputStream write(InputStream data);

    void close();

}
